package org.example.service;

import io.grpc.stub.StreamObserver;

/**
 * @Author wangjun
 * @Date 2025/3/20 16:02
 */
@FunctionalInterface
public interface GrpcRetryOperation<T, R> {
    void execute(T stub, StreamObserver<R> responseObserver) throws Exception;
}
